package com.hjy.test;

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringEncoder;

import java.net.InetSocketAddress;

public class HelloClient {
    public static void main(String[] args) throws InterruptedException {
        new Bootstrap()
                .group(new NioEventLoopGroup())
                //选择客户端Socket 实现类 NioSocketChannel 表示 基于 NIO 实现
                .channel(NioSocketChannel.class)
                // ChannelInitializer 初始化处理器只执行一次  添加 其他的处理器
                .handler(new ChannelInitializer<Channel>() {
                    @Override
                    protected void initChannel(Channel channel) throws Exception {
                        //消息经过当前  handler 处理将 String 转换为  =》 ByteBuf 编码发出
                        channel.pipeline().addLast(new StringEncoder());
                    }
                })
                //指定服务器链接端口
                .connect(new InetSocketAddress("localhost", 8080))
                //netty 中 很多方法都是异步的  如 connect
                //这是需要使用sync 方法等待connect 连接完毕
                .sync()
                // 获取channel 对象  ，它即为通道抽象，可以进行数据读写操作
                .channel()
                //写入消息并清空缓冲区
                .writeAndFlush("hello")
                ;
    }
}
